﻿using Leo.Common.MQ;

namespace Leo.Common.Kafka
{
    public class KafkaProvider : KafkaMessageQueueProviderBase, IMessageQueueProvider
    {
        private readonly KafkaBuilder builder;

        public KafkaProvider(KafkaBuilder builder)
        {
            this.builder = builder;
        }
         
        public override IMQProducer Producer
        {
            get
            {
                return this.builder.Producer;
            }
        } 
        
        public override List<MQConsumerBase> Consumers
        {
            get
            {
                return this.builder.Consumers;
            }
        }
         
     
    }
}
